home *** CD-ROM | disk | FTP | other *** search
/ C/C++ Users Group Library 1996 July / C-C++ Users Group Library July 1996.iso / listings / v_09_01 / 9n01114a < prev    next >
Text File  |  1990-11-27  |  37KB  |  1,472 lines
  1. /*0*********************************************************
  2. *   Richard Carver                            July 1990
  3. * 
  4. *   This program demonstrates interprocess communication
  5. *   between several tasks using the iRMX II Operating
  6. *   System.
  7. *
  8. *   Two tasks are used for resource control.  The
  9. *   clock_task() controls use of the hardware clock and the
  10. *   crt_task() controls use of the display screen.
  11. *
  12. *   The count_task() competes with the clock_task() for
  13. *   use of the crt_task() services.  The timer_task() uses
  14. *   the services of the clock_task() for a software timer.
  15. *
  16. *   The initial task, main(), starts every thing up and,
  17. *   when the timer_task() finishes, shuts everything down.
  18. ***********************************************************/
  19.  
  20. #include <stdio.h>
  21. #include <stdlib.h>
  22. #include <string.h>
  23. #include <rmxc.h>         /* iRMX OS calls & structures   */
  24. #include <rmxerr.h>       /* iRMX status codes (defines)  */
  25. #include <delay.h>        /* Hardcoded delay loop macros  */
  26.  
  27. #define ERROR   (0xFFFF)    /* Error Condition  */
  28.  
  29. #define FALSE   (0)
  30. #define TRUE    (!FALSE)
  31.  
  32. #define MAX_CLOCK_RETRIES   (4)
  33.  
  34. /* The NULL token (similar to NULL pointer) */
  35.  
  36. #define NUL_TKN   ((selector)0)
  37.  
  38. /* Options for rqgettasktokens()  */
  39.  
  40. #define THIS_TASK (0x00)
  41. #define THIS_JOB  (0x01)
  42. #define PARAM_OBJ (0x02)
  43. #define ROOT_JOB  (0x03)
  44.  
  45. /* Options for rqcreatemailbox()  */
  46.  
  47. #define FIFO_OBJ_MBX      (0x0000)
  48. #define PRIORITY_OBJ_MBX  (0x0001)
  49. #define FIFO_DATA_MBX     (0x0020)
  50. #define PRIORITY_DATA_MBX (0x0021)
  51.  
  52. /* Options for rqcreatesemaphore()  */
  53.  
  54. #define FIFO_SEM      (0x0000)
  55. #define PRIORITY_SEM  (0x0001)
  56.  
  57. #define SEM_INIT_0    (0)
  58. #define SEM_MAX_1     (1)
  59.  
  60. /* Common wait times for iRMX System Calls  */
  61.  
  62. #define NO_WAIT       (0x0000)
  63. #define WAIT_FOREVER  (0xFFFF)
  64.  
  65. /* Options for rqcreatetask() */
  66.  
  67. #define NO_FLOAT    (0x0000)
  68. #define DEFAULT_STACK_SIZE    ((unsigned int)2048)
  69.  
  70. /* Task Priorities  */
  71.  
  72. #define CLOCK_TASK_PRIORITY   ((unsigned char)48)
  73. #define TIMER_TASK_PRIORITY       ((unsigned char)150)
  74. #define CRT_TASK_PRIORITY     ((unsigned char)200)
  75. #define COUNT_TASK_PRIORITY   ((unsigned char)200)
  76.  
  77. /* Defines For Hardware Clock */
  78. /* Clock Interrupt Level */
  79.  
  80. #define CLOCK_INT_LEVEL (0x26)
  81.  
  82. /* Clock Ports */
  83.  
  84. #define ADR_PORT  ((unsigned short)0xA060)
  85. #define DAT_PORT  ((unsigned short)0xA062)
  86. #define CNT_PORT  ((unsigned short)0xA064)
  87. #define PIO_PORT  ((unsigned short)0xA066)
  88.  
  89. /* Clock Port I/O Operations */
  90.  
  91. #define PIO_READ  ((unsigned char)0x82)
  92. #define PIO_WRITE ((unsigned char)0x80)
  93.  
  94. /* Clock Registers */
  95.  
  96. #define SEC01_REG (0x00)
  97. #define SEC10_REG (0x01)
  98. #define MIN01_REG (0x02)
  99. #define MIN10_REG (0x03)
  100. #define HRS01_REG (0x04)
  101. #define HRS10_REG (0x05)
  102. #define DAT01_REG (0x07)
  103. #define DAT10_REG (0x08)
  104. #define MON01_REG (0x09)
  105. #define MON10_REG (0x0A)
  106. #define YRS01_REG (0x0B)
  107. #define YRS10_REG (0x0C)
  108.  
  109. /* Clock Control Lines */
  110.  
  111. #define CNT_RST     ((unsigned char)0x00)
  112. #define INT_ENB     ((unsigned char)0x20)
  113. #define HOLD_HIGH   ((unsigned char)0x10)
  114. #define HOLD_READ   ((unsigned char)0x30)
  115. #define HOLD_WRITE  ((unsigned char)0x50)
  116.  
  117. /* Defines for months */
  118.  
  119. #define JANUARY     (1)
  120. #define FEBRUARY    (2)
  121. #define MARCH       (3)
  122. #define DECEMBER    (12)
  123.  
  124. /* Time/Date and Timers Data Structure  */
  125.  
  126. #define MAX_TIMERS    (10)
  127.  
  128. struct SYS_TIME_STR
  129.   {
  130.   unsigned char change_flg;
  131.   unsigned char second;
  132.   unsigned char minute;
  133.   unsigned char hour;
  134.   unsigned char date;
  135.   unsigned char month;
  136.   unsigned char year;
  137.  
  138.   struct TIMER_STR
  139.     {
  140.     unsigned char in_use;
  141.     unsigned int  count;
  142.     unsigned int  timeout;
  143.     selector    sem_tkn;
  144.     }timer[MAX_TIMERS];
  145.   };
  146.  
  147. /* Request Message format for the Display Task  */
  148.  
  149. struct CRT_REQ_STR
  150.   {
  151.   unsigned char *msg_ptr;
  152.   unsigned int  row;
  153.   unsigned int  col;
  154.   };
  155.  
  156. /* Object Catalog Names */
  157.  
  158. const unsigned char
  159.   clock_sem_name[] = "\011CLOCK_SEM",
  160.   init_sem_name[] = "\010INIT_SEM";
  161.  
  162. const unsigned char
  163.   time_seg_name[] = "\010TIME_SEG";
  164.  
  165. const unsigned char
  166.   crt_req_mbx_name[] = "\007CRT_MBX";
  167.  
  168. const unsigned char
  169.   crt_shtdwn_sem_name[] = "\012CRT_SHTDWN",
  170.   clock_shtdwn_sem_name[] = "\014CLOCK_SHTDWN",
  171.   count_shtdwn_sem_name[] = "\014COUNT_SHTDWN";
  172.  
  173. /* Days Per Month */
  174.  
  175. const unsigned char
  176.   days_in_month[12] =
  177.   {31, 28, 31, 30, 31, 30, 31, 31, 30, 31, 30, 31};
  178.  
  179. /* Global System Time/Date Structure */
  180.  
  181. selector  sys_time_seg;
  182. struct SYS_TIME_STR *sys_time;
  183.  
  184. /* Task declarations  */
  185.  
  186. void clock_task(void);
  187. void crt_task(void);
  188. void timer_task(void);
  189. void count_task(void);
  190.  
  191. /* Task objects (global for debugging purposes) */
  192.  
  193. selector    clock_tsk;
  194. selector    crt_tsk;
  195. selector    timer_tsk;
  196. selector    count_tsk;
  197.  
  198. /*1*********************************************************
  199. * Task:     main()  (the initial task)
  200. *
  201. * Summary:  Starts it all up and shuts it all down.
  202. *
  203. * Caveats:  None
  204. ***********************************************************/
  205.  
  206. void main(void)
  207.   {
  208.   selector  current_job;      /* current job            */
  209.   selector  init_sem;         /* initilaization sem     */
  210.   selector  clock_sem;        /* time/date shared memory*/
  211.   selector  clock_shtdwn_sem; /* clock_task() shutdown  */
  212.   selector  count_shtdwn_sem; /* count_task() shutdown  */
  213.   selector  crt_shtdwn_sem;   /* crt_task() shutdown    */
  214.   selector  sys_time_seg;     /* time/date data segment */
  215.  
  216.   unsigned int    status;     /* iRMX condition code    */
  217.  
  218.   struct EXCEPTIONSTRUCT  exceptioninfo;
  219.  
  220.  
  221. /*  Disable current task's exception handler  */
  222.  
  223.   rqgetexceptionhandler(&exceptioninfo, &status);
  224.   exceptioninfo.exceptionmode = 0;
  225.   rqsetexceptionhandler(&exceptioninfo, &status);
  226.  
  227. /*  Get Token For Current Job */
  228.  
  229.   current_job = rqgettasktokens(THIS_JOB, &status);
  230.  
  231. /*  Create and catalog the semaphore used for */
  232. /*  accessing the shared clock data.          */
  233.  
  234.   clock_sem = rqcreatesemaphore(SEM_INIT_0,
  235.     SEM_MAX_1, PRIORITY_SEM, &status);
  236.   rqcatalogobject(current_job,
  237.     clock_sem, &clock_sem_name, &status);
  238.  
  239. /*  Create and catalog the semaphore used for */
  240. /*  synchronizing tasks during initialization */
  241. /*  and shutdown.                             */
  242.  
  243.   init_sem = rqcreatesemaphore(SEM_INIT_0,
  244.     99, FIFO_SEM, &status);
  245.   rqcatalogobject(current_job,
  246.     init_sem, &init_sem_name, &status);
  247.  
  248. /*  Create and catalog the segment of memory  */
  249. /*  used to hold the shared time/date data.   */
  250.  
  251.   sys_time_seg = rqcreatesegment(
  252.     sizeof(struct SYS_TIME_STR), &status);
  253.   rqcatalogobject(current_job,
  254.     sys_time_seg, &time_seg_name, &status);
  255.  
  256. /*  Create and catalog the semaphores used to */
  257. /*  signal task shutdown.                     */
  258.  
  259.   clock_shtdwn_sem = rqcreatesemaphore(SEM_INIT_0,
  260.     SEM_MAX_1, FIFO_SEM, &status);
  261.   rqcatalogobject(current_job,
  262.     clock_shtdwn_sem, &clock_shtdwn_sem_name, &status);
  263.  
  264.   crt_shtdwn_sem = rqcreatesemaphore(SEM_INIT_0,
  265.     SEM_MAX_1, FIFO_SEM, &status);
  266.   rqcatalogobject(current_job,
  267.     crt_shtdwn_sem, &crt_shtdwn_sem_name, &status);
  268.  
  269.   count_shtdwn_sem = rqcreatesemaphore(SEM_INIT_0,
  270.     SEM_MAX_1, FIFO_SEM, &status);
  271.   rqcatalogobject(current_job,
  272.     count_shtdwn_sem, &count_shtdwn_sem_name, &status);
  273.  
  274. /*  Create the crt_task().  Wait for the task to  */
  275. /*  indicate it has completed initialization.     */
  276.  
  277.   crt_tsk = rqcreatetask(CRT_TASK_PRIORITY, &crt_task,
  278.     NUL_TKN, NULL, DEFAULT_STACK_SIZE, NO_FLOAT, &status);
  279.  
  280.   rqreceiveunits(init_sem, 1, WAIT_FOREVER, &status);
  281.  
  282. /*  Create the clock_task().  Wait for the task   */
  283. /*  to indicate it has completed initialization.  */
  284.  
  285.   clock_tsk = rqcreatetask(CLOCK_TASK_PRIORITY, &clock_task,
  286.     NUL_TKN, NULL, DEFAULT_STACK_SIZE, NO_FLOAT, &status);
  287.  
  288.   rqreceiveunits(init_sem, 1, WAIT_FOREVER, &status);
  289.  
  290. /*  Create the count_task().  Wait for the task   */
  291. /*  to indicate it has completed initialization.  */
  292.  
  293.   count_tsk = rqcreatetask(COUNT_TASK_PRIORITY, &count_task,
  294.     NUL_TKN, NULL, DEFAULT_STACK_S